package rabbit_mq

import "context"

type Producer interface {
	Publish(ctx context.Context, msg []byte, priority Priority) error
}
